BaseStatelessReplayLastSubjectAsync class¶

Summary¶

View source

        Provides a base class for stateless, asynchronous subjects that replay the last value to new subscribers and support
        resuming after errors or completion. Designed for scenarios where observers may join at any time and should receive
        the most recent value, if available.
        

classDiagram
class BaseStatelessReplayLastSubjectAsync~T~
class ObservableAsync~T~
ObservableAsync~T~ <|-- BaseStatelessReplayLastSubjectAsync~T~
class ISubjectAsync~T~ {
    <>
}
ISubjectAsync~T~ <|.. BaseStatelessReplayLastSubjectAsync~T~
class IObserverAsync~T~ {
    <>
}
IObserverAsync~T~ <|.. BaseStatelessReplayLastSubjectAsync~T~
class IAsyncDisposable {
    <>
}
IAsyncDisposable <|.. BaseStatelessReplayLastSubjectAsync~T~
class IObservableAsync~T~ {
    <>
}
IObservableAsync~T~ <|.. BaseStatelessReplayLastSubjectAsync~T~

Inherits from: ObservableAsync

Implements: ISubjectAsync, IObserverAsync, IAsyncDisposable, IObservableAsync

Remarks¶

This abstract class implements asynchronous observer and observable patterns, allowing derived classes to define custom notification, error handling, and completion behaviors. It manages observer subscriptions and ensures that the most recent value (if any) is replayed to new subscribers. Thread safety is provided for concurrent access and notification. Typical use cases include event streaming, stateful data flows, or scenarios where late subscribers should receive the latest state.

Constructors¶

Methods¶